package com.example.styconsumer.controller;

import com.alibaba.dubbo.config.annotation.Reference;
import com.example.styinterface.interfaces.IKafkaService;
import org.springframework.web.bind.annotation.*;

@RestController
@RequestMapping("/kafka")
public class KafkaController {
    @Reference
    IKafkaService kafkaService;
    @PostMapping("/send/{input}")
    public void sendMsg(@PathVariable String input) {
        kafkaService.sendFoo(input);
    }
}
